package com.sojson.project.filedepot.service.impl;

import java.util.ArrayList;
import java.util.List;

import javax.annotation.Resource;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.sojson.project.filedepot.dao.FileDepotDao;
import com.sojson.project.filedepot.entity.dto.FileDepotDto;
import com.sojson.project.filedepot.entity.dto.FileDepotPageDto;
import com.sojson.project.filedepot.entity.po.FileDepot;
import com.sojson.project.filedepot.entity.vo.FileDepotVo;
import com.sojson.project.filedepot.entity.vo.FileFieldVo;
import com.sojson.project.filedepot.entity.vo.FileTableVo;
import com.sojson.project.filedepot.service.FileDepotService;
import com.sojson.project.filedepot.service.impl.thread.FileDepotThreadImpl;
import com.sojson.util.BeanUtil;

/**
 * 文件库Service实现类
 * 
 * @author liu
 * @date 2022-10-27
 */
@Service
public class FileDepotServiceImpl extends ServiceImpl<FileDepotDao, FileDepot> implements FileDepotService {

    @Autowired
    private FileDepotThreadImpl fileDepotThreadImpl;
    @Resource
    private FileDepotDao fileDepotDao;

    /**
     * 通过对象查找
     * 
     * @param dto
     * @return
     */
    @Override
    public List<FileDepotVo> list(FileDepotDto dto) {
        List<FileDepotVo> list = fileDepotDao.list(dto);
        return list;
    }

    /**
     * 通过对象分页查找
     * 
     * @param dto
     * @return
     */
    @Override
    public List<FileDepotVo> page(FileDepotPageDto dto) {
        List<FileDepotVo> page = fileDepotDao.page(dto);
        return page;
    }

    /**
     * 通过对象删除
     * 
     * @param dto
     * @return
     */
    @Override
    public int removeByDto(FileDepotDto dto) {
        return fileDepotDao.removeByDto(dto);
    }

    /**
     * 清空数据
     * 
     * @return
     */
    @Override
    public boolean clear() {
        fileDepotDao.clear();
        return true;
    }

    /**
     * 通过id查找
     * 
     * @param id
     * @return
     */
    @Override
    public FileDepotVo findById(String id) {
        FileDepotVo findById = fileDepotDao.findById(id);
        return findById;
    }

    /**
     * 根据访问路径统计数量
     * 
     * @param url
     * @return
     */
    @Override
    public int countByUrl(String url) {
        return fileDepotDao.countByUrl(url);
    }

    /**
     * 根据存储路径统计数量
     * 
     * @param path
     * @return
     */
    @Override
    public int countByPath(String path) {
        return fileDepotDao.countByPath(path);
    }

    /**
     * 通过Url更新
     * 
     * @param dto
     * @return
     */
    @Override
    public int updateByUrl(FileDepotDto dto) {
        return fileDepotDao.updateByUrl(dto);
    }

    /**
     * 通过Url更新
     * 
     * @param dto
     * @return
     */
    @Override
    public int updateByUrlArr(FileDepotDto dto) {
        return fileDepotDao.updateByUrlArr(dto);
    }

    /**
     * 通过Url更新
     * 
     * @param dto
     * @return
     */
    @Override
    public int updateByUrlList(FileDepotDto dto) {
        return fileDepotDao.updateByUrlList(dto);
    }

    /**
     * 通过Path更新
     * 
     * @param dto
     * @return
     */
    @Override
    public int updateByPath(FileDepotDto dto) {
        return fileDepotDao.updateByPath(dto);
    }

    /**
     * 通过Path更新
     * 
     * @param dto
     * @return
     */
    @Override
    public int updateByPathArr(FileDepotDto dto) {
        return fileDepotDao.updateByPathArr(dto);
    }

    /**
     * 通过Path更新
     * 
     * @param dto
     * @return
     */
    @Override
    public int updateByPathList(FileDepotDto dto) {
        return fileDepotDao.updateByPathList(dto);
    }

    /**
     * 通过Url更新状态
     * 
     * @param dto
     * @return
     */
    @Override
    public int updateStatusByUrl(FileDepotDto dto) {
        return fileDepotDao.updateStatusByUrl(dto);
    }

    /**
     * 通过Path更新状态
     * 
     * @param dto
     * @return
     */
    @Override
    public int updateStatusByPath(FileDepotDto dto) {
        return fileDepotDao.updateStatusByPath(dto);
    }

    /**
     * 通过访问路径集合更新状态
     * 
     * @param dto
     * @return
     */
    @Override
    public int updateStatusByUrlArr(FileDepotDto dto) {
        return fileDepotDao.updateStatusByUrlArr(dto);
    }

    /**
     * 通过存储路径更新状态
     * 
     * @param dto
     * @return
     */
    @Override
    public int updateStatusByPathArr(FileDepotDto dto) {
        return fileDepotDao.updateStatusByPathArr(dto);
    }

    /**
     * 通过访问路径集合更新状态
     * 
     * @param dto
     * @return
     */
    @Override
    public int updateStatusByUrlList(FileDepotDto dto) {
        return fileDepotDao.updateStatusByUrlList(dto);
    }

    /**
     * 通过存储路径更新状态
     * 
     * @param dto
     * @return
     */
    @Override
    public int updateStatusByPathList(FileDepotDto dto) {
        return fileDepotDao.updateStatusByPathList(dto);
    }

    /**
     * 根据对象查询存储路径
     * 
     * @param dto
     * @return
     */
    @Override
    public List<FileDepotVo> listPath(FileDepotDto dto) {
        return fileDepotDao.listPath(dto);
    }

    /**
     * 获取未关联的文件的存储路径
     * 
     * @param vo
     * @param isIncludeOrderRelation    是否包含订单关联文件
     * @return
     */
    @Override
    public List<FileDepotVo> getPathList(FileTableVo vo, boolean isIncludeOrderRelation) {
        List<FileFieldVo> fields = vo.getFields();
        List<FileFieldVo> arrayList = null;

        if (isIncludeOrderRelation) {
            arrayList = fields;
        } else {
            arrayList = new ArrayList<>();
            for (FileFieldVo fileField : fields) {
                if (!fileField.getIsOrderRelation()) {
                    arrayList.add(fileField);
                }
            }
        }

        if (arrayList.size() == 0) {
            return new ArrayList<>(0);
        }
        FileTableVo ft = new FileTableVo();
        BeanUtil.copyBeanProp(ft, vo);
        ft.setFields(arrayList);
        return fileDepotDao.getPathList(ft);
    }

    /**
     * 获取未关联的文件的存储路径
     * 
     * @param vo
     * @param isIncludeOrderRelation    是否包含订单关联文件
     * @return
     */
    @Override
    public List<FileDepotVo> getPathListByPath(FileTableVo vo, boolean isIncludeOrderRelation) {
        List<FileFieldVo> fields = vo.getFields();
        List<FileFieldVo> arrayList = null;

        if (isIncludeOrderRelation) {
            arrayList = fields;
        } else {
            arrayList = new ArrayList<>();
            for (FileFieldVo fileField : fields) {
                if (!fileField.getIsOrderRelation()) {
                    arrayList.add(fileField);
                }
            }
        }

        if (arrayList.size() == 0) {
            return new ArrayList<>(0);
        }
        FileTableVo ft = new FileTableVo();
        BeanUtil.copyBeanProp(ft, vo);
        ft.setFields(arrayList);
        return fileDepotDao.getPathListByPath(ft);
    }

    /**
     * 获取订单关联关系的文件的存储路径
     * 
     * @param vo
     * @return
     */
    @Override
    public List<FileDepotVo> getOrderRelationPathList(FileTableVo vo) {
        List<FileFieldVo> fields = vo.getFields();
        List<FileFieldVo> arrayList = new ArrayList<>();

        for (FileFieldVo fileField : fields) {
            if (fileField.getIsOrderRelation()) {
                arrayList.add(fileField);
            }
        }

        if (arrayList.size() == 0) {
            return new ArrayList<>(0);
        }
        FileTableVo ft = new FileTableVo();
        BeanUtil.copyBeanProp(ft, vo);
        ft.setFields(arrayList);
        return fileDepotDao.getOrderRelationPathList(ft);
    }

    /**
     * 获取订单关联关系的文件的存储路径
     * 
     * @param vo
     * @return
     */
    @Override
    public List<FileDepotVo> getOrderRelationPathListByPath(FileTableVo vo) {
        List<FileFieldVo> fields = vo.getFields();
        List<FileFieldVo> arrayList = new ArrayList<>();

        for (FileFieldVo fileField : fields) {
            if (fileField.getIsOrderRelation()) {
                arrayList.add(fileField);
            }
        }

        if (arrayList.size() == 0) {
            return new ArrayList<>(0);
        }
        FileTableVo ft = new FileTableVo();
        BeanUtil.copyBeanProp(ft, vo);
        ft.setFields(arrayList);
        return fileDepotDao.getOrderRelationPathListByPath(ft);
    }

    /**
     * 清空旧文件
     * 
     * @return
     */
    @Override
    public void clearFile() {
        fileDepotThreadImpl.clearFile();
    }

    /**
     * 异常后的警告
     */
    @Override
    public void clearImgMonthWarn() {
        // TODO
    }

}